/**
 * 
 */
package sources;

import java.io.File;
import java.io.IOException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.google.common.io.Files;
import com.google.common.io.LineProcessor;

/**
 * @author Kyniek
 *
 */
public class SplitSourceWraper implements IWrapper
{
	
	
	private final Map<String, List<Object>> datas = new HashMap<String, List<Object>>();
	
	private List<ISource> sources;
	

	/**
	 * Konstruktor wrapera wyodrębniającego z pojedynczego pliku źródła. Lista kolumn musi mieć taką samą długość jak lista typów.
	 * Każdy element listy nazw kolumn musi mieć odpowiadający element w liście typów. Domyślnym separatorem kolumn jest biały znak
	 * @param file plik z którego mają być odczytane dane. Dane muszą być zapisane w kolumnach podzielone separatorem
	 * @param cols lista nazw kolumn - obowiązująca w bazie danych
	 * @param types lista typów dla wymienionych kolumn
	 */
	public SplitSourceWraper(String file, List<String> cols, List<String> types)
	{
		this(file, cols, types, "\\s");
	}
	
	
	/**
	 * Konstruktor wrapera wyodrębniającego z pojedynczego pliku źródła. Lista kolumn musi mieć taką samą długość jak lista typów.
	 * Każdy element listy nazw kolumn musi mieć odpowiadający element w liście typów. Domyślnym separatorem kolumn jest spacja
	 * @param file plik z którego mają być odczytane dane. Dane muszą być zapisane w kolumnach podzielone separatorem
	 * @param cols lista nazw kolumn - obowiązująca w bazie danych
	 * @param types lista typów dla wymienionych kolumn
	 * @param colSeparator separuje kolumny, może to być przykładowo ";" lub ","
	 */
	public SplitSourceWraper(String file, final List<String> cols, final List<String> types, final String colSeparator)
	{		
		for(String col : cols)
		{
			datas.put(col, new ArrayList<Object>());
		}
		
		try
		{
			sources = Files.readLines(new File(file),Charset.forName("UTF-8"), new LineProcessor<List<ISource>>() 
			{
				//List<Object> result = new ArrayList<Object>();

				boolean firstLine = true;
				
				@Override
				public List<ISource> getResult()
				{
					List<ISource> result = new ArrayList<ISource>();
					
					for(int i = 0; i < cols.size(); i++)
					{
						result.add(new SimpleSource(datas.get(cols.get(i)), cols.get(i), types.get(i)));
					}
					
					return result;
				}
	
				@Override
				public boolean processLine(String arg0) throws IOException
				{					
					if(firstLine)
					{
//						String[] tab = arg0.split("\\s");
//						System.out.println(tab.length);
//						for(String s : tab)
//						{
//							System.out.println("- " + s);
//						}
						
						
//						System.out.println(arg0);
						firstLine = false;
						char[] strs = arg0.toCharArray();
						arg0 = "";
						for(Character ch : strs)
						{
							//System.out.println("___" + ch + ":" + Character.getNumericValue(ch) );
							if(Character.getNumericValue(ch) >= 0)
							{
								arg0 += ch;
							}
							else if (arg0.length() > 0)
							{
								arg0 += " ";
							}
						}
					}
					//result.add(arg0);
					//mając linię należy ją rozbić na kolumny
					String[] tab = arg0.split(colSeparator);
					
//					for(String ta : tab)
//					{
//						System.out.println("- " + ta);
//					}
					
					for(int i = 0; i < tab.length && i < cols.size(); i++)
					{
						//System.out.println("i : " + i + " tab : " + tab.length + " cols : " + cols.size());
						datas.get(cols.get(i)).add(tab[i]);
					}
					
					
					return true;
				}
		} );
		} catch (IOException e)
		{
			e.printStackTrace();
		}
		
		
	}
	
	
	/**
	 * konstruktor z pliku wyodrębnia listę kolumn i przydziela każdy element tej listy do listy źródeł
	 * @param file
	 * @param srcs
	 */
	public SplitSourceWraper(String file, List<ISource> srcs)
	{
		this(file, srcs, "\\s");
	}
	
	
	public SplitSourceWraper(String file, List<ISource> srcs, String separator)
	{
		;
	}

	/* (non-Javadoc)
	 * @see sources.IWrapper#getAll()
	 */
	@Override
	public List<ISource> getAll()
	{		
		return sources;
	}

}
